package kafka

import (
	"context"
	"im/models"
	"im/servers/websocket"
)

func SendUserMessage(ctx context.Context, msg *models.CustomKafkaMsg) (err error) {
	//是否指定私聊
	if msg.UserId == "" {
		_, err = websocket.SendUserMessage(msg.AppId, msg.UserId, msg.MsgId, msg.Data.(string))
		return err
	} else {
		_, err = websocket.SendUserMessageAll(msg.AppId, msg.UserId, msg.MsgId, models.MessageCmdMsg, msg.Data.(string))
		return err
	}
}
